package com.streamax.s17.mqs.business.config;

import lombok.Data;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * @Description
 * @ClassName KafkaConfig
 * @Author liwei
 * @Date 2020/1/6 15:06
 * @Version 2.0.X
 */
@Getter
@Setter
@ToString(callSuper = true)
@ConfigurationProperties(prefix = "spring.kafka")
public class KafkaConfig {
    private String bootstrapServers;
    private Consumer consumer;
    @Getter
    @Setter
    public static class Consumer{
        private String groupId;
        private String clientId;
        private String[] topics;
    }
}
